package com.test.reactor_test;

import org.reactivestreams.Publisher;

/**
 * @author zxs
 * @version 1.0
 * @date 2019-03-18
 */
public abstract class Flux<T> implements Publisher<T> {
    public static <T> Flux<T> just(T... data){
        return new FluxArray<T>(data);
    }
}
